package com.kafka.service.carMsg;


/**
 * 观察者主题对象
 */
public interface CarObserver {
    /**
     * 订阅
     * @param o
     */
    public void registerObserver(MsgObserver o);

    /**
     * 移除
     * @param o
     */
    public void removeObserver(MsgObserver o);

    /**
     * 通知
     */
    public void notifyObserver();
}
